package com.dtwave.webservice;

import com.sun.org.slf4j.internal.Logger;
import com.sun.org.slf4j.internal.LoggerFactory;
import org.apache.flink.api.java.utils.ParameterTool;

import java.lang.reflect.Parameter;
import java.util.Properties;


/*
* --database.url jdbc.oracle:thin:@172.28.3.187:152:DWSIT
* --database.driver oracle.jdbc.drivcer.OracleDriver
* --database.username MET
* --database.password Fouder123
* --clusterName elasticsearch
* --hosts 172.28.30.165
* --port 9300
* --stream_index ss_20190603
* --batch_index lx_201906
* --type_name acct_no
* --updateFieldName acct_no
* --processTime 20190516
* --state_index sync
* --base_dir datax
* --template dataxtemplate
* --query.state.sql
* --esHttpUrl http://dddd:9200/
*
* */

public class DataSyncAndUpdate {

    static final Logger logger = LoggerFactory.getLogger(DataSyncAndUpdate.class);

    public static void main(String[] args) {

        Properties properties = null;
        String msg = "完成";
        String processTime = "";

        ParameterTool parameterTool = ParameterTool.fromArgs(args);

        processTime = parameterTool.get("process", "20190522");



    }


}
